async-priority-channel
An async channel where pending messages are delivered in order of priority.
There are two kinds of channels:
- Bounded channel with limited capacity.
- Unbounded channel with unlimited capacity.
A channel has the Sender
and Receiver
side. Both sides are cloneable and can be shared
among multiple threads. When sending, you pass in a message and its priority. When receiving,
you'll get back the pending message with the highest priotiy.
When all Sender
s or all Receiver
s are dropped, the channel becomes closed. When a
channel is closed, no more messages can be sent, but remaining messages can still be received.
The channel can also be closed manually by calling Sender::close()
or
Receiver::close()
. The API and much of the documentation is based on async_channel.
Examples
let = unbounded;
assert_eq!;
assert_eq!;
assert_eq!;
assert_eq!;
License: Apache-2.0 OR MIT